package com.apps.sdses.flink141;

import com.alibaba.fastjson2.JSONObject;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

import java.io.Serializable;
import java.util.List;

@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public class DebeziumRecord implements Serializable {

    @JsonProperty(value ="op")
    public String op;

    @JsonProperty(value ="before")
    public JSONObject before;

    @JsonProperty(value ="after")
    public JSONObject after;

    @JsonProperty(value ="source")
    public DebeziumSourceRecord source;

    @JsonProperty(value ="pkNames", required = true)
    public List<String> pkNames;

    @JsonProperty(value ="pkName", required = true)
    public String pkName;

    @JsonProperty(value ="pkValue", required = true)
    public String pkValue;

    @JsonProperty(value ="ts_ms")
    public Long tsMs;

}